// publisher.js 生产者
require('dotenv').config({ path: `./.env.${process.env.NODE_ENV.trim()}` }) // 环境变量注入
const redis = require('../db/redis')

setInterval(async () => {
  const message = { foo: Math.random() }
  // Publish to my-channel-1 or my-channel-2 randomly.
  // const channel = `my-channel-${1 + Math.round(Math.random())}`

  // Message can be either a string or a buffer
  // 发布消息示例
  await client.xadd('ocr_stream', '*', 'message', JSON.stringify(message)); // stream模式 redis版本需要5.0以上
  console.log('Published %s to %s', message, 'ocr_stream')
}, 1000)
